package com.ruoyi.wisdom.task;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Component
public class HeartbeatTask extends IotTask{

    @Autowired
    @Qualifier("redisSecondTemplate")
    public RedisTemplate redisSecondTemplate;

    @Autowired
    @Qualifier("redisTemplate")
    public RedisTemplate redisTemplate;

    // 每隔一定时间发送一次心跳，例如每1分钟执行一次
    @Scheduled(fixedRate = 60 * 1000)
    public void sendHeartbeat() {
        // 这里可以设置一个key，value可以是任何东西，表示发送了一次心跳
        redisTemplate.opsForValue().set("heartbeat", "alive");
        redisSecondTemplate.opsForValue().set("heartbeat", "alive");
    }
}
